package com.gengzp.mq.common.constants;

/**
 * @ClassName GengzpMqCacheConstants
 * @Description 消息队列模块缓存key常量池
 * @Author gengzp
 * @Date 2025/6/8 15:04
 */
public interface GengzpMqCacheConstants {

    // 消息缓存key前缀
    String MESSAGE_KEY_PREFIX = "gengzp_mq:topic:";

    // 处理中消息缓存key前缀
    String PROCESSING_MESSAGE_KEY_PREFIX = "gengzp_mq:processing:";

    // 消息队列中的topic集合前缀
    String TOPIC_INFO_KEY_PREFIX = "gengzp_mq:topic_info:";

    // 消费者服务名key前缀
    String TOPIC_CONSUMER_SERVICE_NAME_KEY_PREFIX = "gengzp_mq:topic_consumer_relation:";

}
